package source;

import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.streaming.api.environment.LocalStreamEnvironment;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

/**
 * @Description: TODO QQ1667847363
 * @author: xiao kun tai
 * @date:2021/11/2 16:02
 */
public class Environment {
    public static void main(String[] args) {

        //最常用的
        ExecutionEnvironment env =
                ExecutionEnvironment.getExecutionEnvironment();

        StreamExecutionEnvironment stream =
                StreamExecutionEnvironment.getExecutionEnvironment();

        //本地
        LocalStreamEnvironment local =
                StreamExecutionEnvironment.createLocalEnvironment(1);

        //远程
        StreamExecutionEnvironment remote =
                StreamExecutionEnvironment.createRemoteEnvironment(
                        "jobmanage-hostname",
                        6123, "YOURPATH//WordCount.jar");
    }
}
